fa50084c51976e75b6c0917f3a17177e3983186e,tests/test_apps/kafkaimporter/client/kafkaimporter/KafkaImportBenchmark.java,KafkaImportBenchmark,printStatistics,#,179
Before Change
long time = Math.round((stats.getEndTimestamp() - benchmarkStartTS) / 1000.0);
long thrup;
System.out.printf("%02d:%02d:%02d ", time / 3600, (time / 60) % 60, time % 60);
thrup = stats.getTxnThroughput();
System.out.printf("Throughput %d/s, ", thrup);
System.out.printf("Aborts/Failures %d/%d, ",
stats.getInvocationAborts(), stats.getInvocationErrors());
System.out.printf("Avg/95%% Latency %.2f/%.2fms\n", stats.getAverageLatency(),
stats.kPercentileLatencyAsDouble(0.95));
}
/**
After Change
thrup = stats.getTxnThroughput();
log.info(String.format("Throughput %d/s, Aborts/Failures %d/%d, Avg/95%% Latency %.2f/%.2fms",
thrup, stats.getInvocationAborts(), stats.getInvocationErrors(),
stats.getAverageLatency(), stats.kPercentileLatencyAsDouble(0.95)));
}
/**